package com.lkd.emq;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @author Administrator
 */
public interface MqttService {
    /**
     * 消息处理
     * @param topic
     * @param message
     */
    void processMessage(String topic, MqttMessage message);
}
